package com.gxgeek.springbootwebfluxlearning.reposity;

import com.gxgeek.springbootwebfluxlearning.event.MyEvent;
import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
import org.springframework.data.mongodb.repository.Tailable;
import reactor.core.publisher.Flux;

/**
 * @author gaoxing
 * @create 2018-04-17 下午2:37
 */
public interface MyEventRepository extends ReactiveMongoRepository<MyEvent, Long> { // 1
    @Tailable
        // 1
    Flux<MyEvent> findBy(); // 2

}
